package com.qupeng.demo.kafka.kafkaspringbootconsumer.config;

import com.fasterxml.jackson.databind.JavaType;
import com.fasterxml.jackson.databind.type.TypeFactory;
import com.qupeng.demo.kafka.kafkaspringbootconsumer.model.Product;
import org.apache.kafka.common.header.Headers;

public class TypeMapper {
    public static JavaType thing1Thing2JavaTypeForTopic(String topic, byte[] data, Headers headers) {
        return TypeFactory.defaultInstance().constructType(Product.class);
    }
}
